using System.Text;
using Org.Apache.Rocketmq;
using Vin.Extension.RocketMQ.Models;

namespace RocketMQ.Api.Tests.Consumer;

public class TestNormalConsumer2 : VinConsumer
{
    protected override string Group { get; } = "test-normal-group1";

    protected override Dictionary<string, FilterExpression> FilterExpressions { get; } = new()
    {
        {
            "test-normal1", new FilterExpression("*")
        }
    };

    public override ConsumeResult Consume(MessageView messageView)
    {
        Console.WriteLine($"Consume2 Data={Encoding.UTF8.GetString(messageView.Body)}");
        return ConsumeResult.SUCCESS;
    }
}